# customer增量（含更新）

 /usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select *, '2022-10-14' as dt from customer  where 1=1 and (create_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') or (update_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table customer  \
-m 1

# customer_appeal 增量（含更新）

 /usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select *, '2022-10-14' as dt from customer_appeal  where 1=1 and (create_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') or (update_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table customer_appeal  \
-m 1

# customer_clue 增量（含更新）

 /usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select *, '2022-10-14' as dt from customer_clue  where 1=1 and (create_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') or (update_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table customer_clue  \
-m 1



# customer_relationship 增量（含更新）

 /usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select *, '2022-10-14' as dt from customer_relationship  where 1=1 and (create_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') or (update_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table customer_relationship  \
-m 1

# employee（增量（含更新））
 /usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select *, '2022-10-14' as dt from employee  where 1=1 and (create_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') or (update_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table employee  \
-m 1

# itcast_clazz（增量（含更新））
 /usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select *, '2022-10-14' as dt from itcast_clazz  where 1=1 and (create_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') or (update_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table itcast_clazz  \
-m 1

# itcast_school 全量覆盖
/usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select * from itcast_school  where 1=1 and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table itcast_school \
-m 1

# itcast_subject 全量覆盖
/usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select * from itcast_subject  where 1=1 and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table itcast_subject \
-m 1

# scrm_department（增量（含更新））
 /usr/bin/sqoop import "-Dorg.apache.sqoop.splitter.allow_text_splitter=true" \
--connect 'jdbc:mysql://106.75.33.59:3306/scrm?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true' \
--username itcast_edu_stu \
--password itcast_edu_stu \
--query "select *, '2022-10-14' as dt from scrm_department  where 1=1 and (create_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') or (update_date_time between '1970-01-01 00:00:00' and '2022-10-13 23:59:59') and  \$CONDITIONS" \
--hcatalog-database bxg_ods \
--hcatalog-table scrm_department  \
-m 1